package com.lgy.message;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

public interface StreamInput {

    String INPUT = "input";
    String INPUT2 = "input2";

    @Input(StreamInput.INPUT)
    SubscribableChannel input();

    @Input(StreamInput.INPUT2)
    SubscribableChannel input2();
}
